import pymysql
from config.Readconfig import Read_config
from log.log import Log
log=Log()
config_sql=Read_config().mysql
class sql_data:
    def __init__(self):

        self.curr = pymysql.connect(**config_sql)  # 连接数据库
        self.sql_cursor = self.curr.cursor()  # 光标
    def ex_sql(self,value=None):
        try:
            self.sql_cursor.execute(value)
            self.curr.commit()#提交修改，没有这个无法执行删除等操作，可以执行查询

            log.sql_implement(value)
        except pymysql.err.OperationalError:

            raise pymysql.err.OperationalError('没有链接数据库')
        except:
            log.log.info("执行{}失败".format(value))

        finally:
            self.sql_cursor.close()
            self.curr.close()
    def sql_assert(self,sql):
        self.ex_sql(sql)
        return self.sql_cursor.fetchall()

    def exc_sql(self,value):
        self.ex_sql(value)
        return self.sql_cursor.fetchall()





